# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.sensors.hive_partition_sensor import HivePartitionSensor

jms_dwd__dwd_cn_address_warehouse_es_dt_check = HivePartitionSensor(
    pool='unlimited_pool',
    task_id='jms_dwd__dwd_cn_address_warehouse_es_dt_check',
    name='jms_dwd__dwd_cn_address_warehouse_es_dt_check_{{ execution_date | cst_ds }}',  # yarn 任务名称
    email=['yushuo@jtexpress.com','yl_bigdata@yl-scm.com'],
    table='cn_address_warehouse_es',
    partition="dt='{{ execution_date | cst_ds_nodash }}'",
    schema='dwb',
    poke_interval=60,
    mode='reschedule',
    timeout=timedelta(hours=6).seconds,
)

